View Javadoc
   /*
    * Created by IntelliJ IDEA.
    * User: birchfield
    * Date: Aug 18, 2002
    * Time: 4:55:54 PM
    * To change template for new class use
    * Code Style | Class Templates options (Tools | IDE Options).
    */
   package net.plugin.sql.util;
  
  import net.plugin.sql.beans.DataSource;
  import net.plugin.sql.listeners.DataSourceChangeListener;
  
  import java.util.*;
  import java.sql.Connection;
  
  import com.intellij.openapi.project.Project;
  
  public class DataSourceManager {
  
      private final static HashMap instances = new HashMap(10);
  
      private Collection datasources = null;
      private Collection listeners = null;
  
      private DataSourceManager() {
          datasources = new ArrayList();
          listeners = new ArrayList();
      }
  
      public static DataSourceManager getInstance(Project project) {
  	    System.out.println("getInstance project = " + project);
  	    DataSourceManager result = (DataSourceManager) instances.get(project);
          if(result == null) {
  	        result = new DataSourceManager();
  	        instances.put(project, result);
          }
          return result;
      }
  
      public synchronized void addDataSource(DataSource dataSource) throws DataSourceException {
          for (Iterator iterator = datasources.iterator(); iterator.hasNext();) {
              DataSource source = (DataSource) iterator.next();
              if (dataSource.getName().equals(source.getName())) {
                  System.out.println("duplicate name...");
                  throw new DataSourceException("A datasource with that name already exists!");
              }
          }
          JDBCConnectionManager jdbcmanager = new JDBCConnectionManager(dataSource);
          Connection conn = jdbcmanager.getConnection();
          if (conn != null) {
              System.out.println("Adding datasource: " + dataSource);
              datasources.add(dataSource);
              notifyListeners();
          }
      }
  
      public synchronized void removeDataSource(DataSource dataSource) {
          for (Iterator iterator = datasources.iterator(); iterator.hasNext();) {
              DataSource source = (DataSource) iterator.next();
              if (source.getName().equals(dataSource.getName())) {
                  iterator.remove();
              }
          }
      }
  
      public synchronized DataSource getDataSource(String name) {
          for (Iterator iterator = datasources.iterator(); iterator.hasNext();) {
              DataSource dataSource = (DataSource) iterator.next();
              if (name.equals(dataSource.getName())) {
                  return dataSource;
              }
          }
          return null;
      }
  
      public synchronized Collection getDataSources() {
          Collection datasourcesCopy = new ArrayList(datasources.size());
          for (Iterator iterator = datasources.iterator(); iterator.hasNext();) {
              DataSource dataSource = (DataSource) iterator.next();
              datasourcesCopy.add(dataSource);
          }
          return datasourcesCopy;
      }
  
      private void notifyListeners() {
          for (Iterator iterator = listeners.iterator(); iterator.hasNext();) {
              DataSourceChangeListener dataSourceChangeListener = (DataSourceChangeListener) iterator.next();
              dataSourceChangeListener.dataSourcesChanged();
          }
      }
  
      public void addDataSourceListener(DataSourceChangeListener listener) {
          listeners.add(listener);
      }
  
  }